package quorum;

import common.Message;

public class NewBornListener extends Thread{
	boolean pushReceived = false;
	
	public void run(){
		try {
			Thread.sleep(timer.aliveTime+30000);
		} catch (InterruptedException e) {
			if(pushReceived){
				return;
			}
		}
		String s = new String("NEWBORN");
		Message m=new Message(s.getBytes());
		m.setSource(Quorum.getInstance());
		Quorum.getInstance().getGlobalBroadcast().broadcast(m);
	}
}
